Prometheus Proxy/io.prometheus.proxy

Package-level declarations

Types

internal class AgentContext(remoteAddr: String)

Represents a single connected agent on the proxy side.

AgentContextCleanupService

internal class AgentContextCleanupService(proxy: Proxy, configVals: ConfigVals.Proxy2.Internal2, initBlock: AgentContextCleanupService.() -> Unit = {}) : GenericExecutionThreadService

Background service that periodically evicts stale agent contexts.

AgentContextManager

internal class AgentContextManager(isTestMode: Boolean)

Registry for connected agents and in-flight chunked scrape contexts.

internal class ChunkedContext(response: ChunkedScrapeResponse, maxZippedContentSize: Long)

Accumulates chunked scrape response data with CRC32 integrity validation.

ChunkValidationException

internal class ChunkValidationException(message: String) : Exception

object ProxyConstants

ProxyGrpcService

internal class ProxyGrpcService(proxy: Proxy, port: Int = -1, inProcessName: String = "") : GenericIdleService

Manages the gRPC server lifecycle for the proxy.

ProxyHttpConfig

internal object ProxyHttpConfig

ProxyHttpRoutes

object ProxyHttpRoutes

HTTP routing logic for the proxy's Ktor server.

ProxyHttpService

internal class ProxyHttpService(proxy: Proxy, val httpPort: Int, isTestMode: Boolean) : GenericIdleService

HTTP server that serves Prometheus scrape requests.

internal class ProxyMetrics(proxy: Proxy)

class ProxyOptions(args: Array<String>) : BaseOptions

ProxyPathManager

internal class ProxyPathManager(proxy: Proxy, isTestMode: Boolean)

Maps scrape URL paths to their registered AgentContext instances.

ProxyServerInterceptor

internal class ProxyServerInterceptor : ServerInterceptor

ProxyServerTransportFilter

internal class ProxyServerTransportFilter(proxy: Proxy) : ServerTransportFilter

ProxyServiceImpl

internal class ProxyServiceImpl(proxy: Proxy) : ProxyServiceGrpcKt.ProxyServiceCoroutineImplBase

Server-side implementation of the ProxyService gRPC service.

object ProxyUtils

ResponseResults

data class ResponseResults(val statusCode: HttpStatusCode = HttpStatusCode.OK, val contentType: ContentType = Text.Plain.withCharset(Charsets.UTF_8), val contentText: String = "", val updateMsgs: List<String> = emptyList())

ScrapeRequestManager

internal class ScrapeRequestManager

Tracks in-flight scrape requests and assigns results when responses arrive.

ScrapeRequestResponse

data class ScrapeRequestResponse(val statusCode: HttpStatusCode, val updateMsg: String, val contentType: ContentType = Text.Plain.withCharset(Charsets.UTF_8), val contentText: String = "", val failureReason: String = "", val url: String = "", val fetchDuration: Duration)

ScrapeRequestWrapper

internal class ScrapeRequestWrapper(val agentContext: AgentContext, proxy: Proxy, pathVal: String, encodedQueryParamsVal: String, authHeaderVal: String, acceptVal: String?, debugEnabledVal: Boolean)